package com.edata.bigdata.flink


import org.apache.flink.streaming.api.scala.{DataStream, StreamExecutionEnvironment}
import org.apache.log4j.Logger


trait Source[T] {
  @transient lazy val LOGGER = Logger.getLogger(this.getClass)
  var env: StreamExecutionEnvironment
  var dataStream: DataStream[T]

  def createDataStream(): Unit

  def start(jobName: String): Unit
}
